package com.gecco.crawler.pipeline;

import com.alibaba.fastjson.JSONObject;
import com.gecco.crawler.htmlbean.MsgDetail;
import com.geccocrawler.gecco.annotation.*;
import com.geccocrawler.gecco.pipeline.Pipeline;

@PipelineName("msgDetailPipeline")
public class MsgDetailPipeline  implements Pipeline<MsgDetail> {
	
    public void process(MsgDetail msgDetail) {
        System.out.println("~~~~~~~~~~~~~~~~~~~~~~ msgDetail管道 ~~~~~~~~~~~~~~~~~~~~~~~~");
        String jsonObj = JSONObject.toJSONString(msgDetail);
        System.out.println(jsonObj);
        System.out.println("标题:"+ msgDetail.getTitle());
        System.out.println("内容:"+ msgDetail.getContent());
    }
}
